package com.futao.techsharingmq.basic.concept.simple.book;

import com.futao.techsharingmq.basic.concept.simple.MqChannelUtils;
import com.rabbitmq.client.Channel;

import java.io.IOException;

/**
 * @author futao@gmail.com
 * @date 2021/11/2
 */
public class Mqtt {
    public static void main(String[] args) throws IOException {
        Channel channel = MqChannelUtils.createChannel();
        channel.queueDeclare("queue-mqtt", true, false, false, null);
        channel.queueBind("queue-mqtt", "amq.topic", "#");
    }
}
